package com.atguigu.tingshu.user.config;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.TopicBuilder;

/***
 * 配置kfk的分片
 */
//@Configuration
public class KafkaTestConfig {

//    @Bean
//    public NewTopic newTopic(){
//
//        return TopicBuilder
//                .name("c")
//                .partitions(3)
//                .replicas(2)
//                .build();
//    }

}
